package com.service.scheduling.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.service.dao.enums.MqMsgVo;
import com.service.dao.enums.SysMqTopicEnum;
import com.service.dao.model.SysMqRecord;

import java.util.List;


/**
 * mq消息记录
 *
 * @author xxxx
 * @email xxxx@qq.com
 * @date 2020-06-09 21:03:01
 */
public interface SysMqRecordService extends IService<SysMqRecord> {

    void saveMqMsgRecord(SysMqTopicEnum topic, MqMsgVo mqMsgVo);

    List<SysMqRecord> listNotReceiveMqMsg(SysMqTopicEnum topic);
}

